
from common.NeqReq import NeqReq
from common.DBManager import DBManager

from utils.yaml_utils import read_yaml



def pre_process(dm:DBManager, pre_path:str):
	pre_data = read_yaml(pre_path)
	for item in pre_data:
		dm.insert_data(item['table'], item['fields'], item['data'])

def aft_process(dm:DBManager, aft_path:str):
	print("aft_pro")
	aft_data = read_yaml(aft_path)
	for item in aft_data:
		dm.delete_data(item['table'], item['field'], item['data'])